from celery import Celery
# 在创建celery实例之前，加载django的配置模块到运行环境中
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'tens.settings.dev'
celery_app = Celery('meiduo')

# 将刚刚的 config 配置给 celery
# 里面的参数为我们创建的 config 配置文件:
celery_app.config_from_object('celery_tasks.config')
 # 就是自动捕获 tasks
# celery_app.autodiscover_tasks(['celery_tasks.sms'])

celery_app.autodiscover_tasks(['celery_tasks.sms',
                                'celery_tasks.email',
                                'celery_tasks.html'])

# 自动注册 celery 任务
# celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email'])